package mapper.yorum;

import infobean.musteri;
import infobean.yorum;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;



import dbDrivers.db2Connection;
import mapper.dbinterface;

public class db2MapperYorum {
	public static dbDrivers.db2islemleri db=new dbDrivers.db2islemleri();
	
	public static ArrayList DataBaseGetObject(Object oid){
		String sql = null ;
		ArrayList<yorum> geri_yorumlar = new ArrayList<yorum>();
		sql= "SELECT * FROM KEYSAN.\"YORUMLAR\" Y, KEYSAN.\"MUSTERI\" M WHERE M.KULLANICI_ID=Y.KULLANICI_ID";
		
		if (oid==null || oid.getClass() == String.class){
			sql= "SELECT * FROM KEYSAN.\"YORUMLAR\" Y, KEYSAN.\"MUSTERI\" M WHERE M.KULLANICI_ID=Y.KULLANICI_ID";
			
		}else if(oid.getClass() == yorum.class  ){
			yorum yr = (yorum) oid;
			sql= "SELECT * FROM KEYSAN.\"YORUMLAR\" Y, KEYSAN.\"MUSTERI\" M WHERE AYGIT_ID="+yr.getAygit().getAygit_id()+" AND M.KULLANICI_ID=Y.KULLANICI_ID";
			
		}
		System.out.println(sql);
		ResultSet rs = db.executeQuery(sql);
		if (rs != null){
		try {
			while(rs.next())
			{

				 System.out.print("HHHEE");
				 try {
					 yorum gelen_yorum = new yorum();
					 gelen_yorum.setBaslik(rs.getString("BASLIK"));
					 gelen_yorum.setTarih(rs.getString("TARIH"));
					 gelen_yorum.setYorum(rs.getString("YORUM"));
					 gelen_yorum.setYorumId(rs.getLong("YORUM_ID"));
					 musteri mus= new musteri();
					 mus.setAd_soyad(rs.getString("MUSTERI_ADI"), rs.getString("MUSTERI_SOYADI"));
					 
					 gelen_yorum.setMus(mus);
					 geri_yorumlar.add(gelen_yorum);
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				 
				
				 
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}}else{
			System.out.println("Resultset boşşş");
		}
		return geri_yorumlar;
	}


	public static boolean DataBaseDeleteObject(Object oid) throws SQLException {
		//if oid.getClass()
		// TODO Auto-generated method stub
		//String sql = "DELETE FROM stok WHERE ilac_id=? AND gelis_tarih =? AND eczane_id =?";
		yorum yr = (yorum) oid;
		String sql = "DELETE FROM KEYSAN.\"YORUMLAR\" WHERE AYGIT_ID="+yr.getAygit().getAygit_id();
		return db.execute(sql);
		//return false;
	}


	public static boolean DataBasePut(Object oid) throws SQLException {
		// TODO Auto-generated method stub
		yorum yr = (yorum) oid;		
		String sql = "insert into KEYSAN.\"YORUMLAR\" (KULLANICI_ID, AYGIT_ID, YORUM," +
			" TARIH, BASLIK) values ("+yr.getKullanici().getKullanici_id()+
			" , " + yr.getAygit().getAygit_id() + " , '"+yr.getYorum()+"'  , '"+yr.getTarih()+"', '"+yr.getBaslik()+"')";
		return db.execute(sql);
		
	}


	public static boolean DataBaseUpdate(Object oid) throws SQLException {
		yorum yr = (yorum) oid;	
		String sql="UPDATE KEYSAN.\"YORUMLAR\" SET KULLANICI_ID="+yr.getKullanici().getKullanici_id()+", AYGIT_ID="+yr.getAygit().getAygit_id()+
		", YORUM = '"+yr.getYorum()+"', TARIH='"+yr.getTarih()+"', BASLIK='"+yr.getBaslik()+"' WHERE YORUM_ID=" +yr.getYorumId();
		return db.execute(sql);
		// TODO Auto-generated method stub
		//return false;
	}
}
